package com.concurrent.sample.common.nats;

import io.nats.client.Connection;
import io.nats.client.Nats;

public class NatsConnUtil {

  public static Connection getConn(NatsProperties natsProperties){
    try {
      return Nats.connect(natsProperties.getUrl());
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

}
